ostree_async_progress_set_uint64 (pull_data->progress, "bytes-transferred", bytes_transferred);
ostree_async_progress_set_uint64 (pull_data->progress, "start-time", start_time);
+ /* We fetch metadata before content. These allow us to report metadata fetch progress specifically. */
+ ostree_async_progress_set_uint (pull_data->progress, "outstanding-metadata-fetches", pull_data->n_outstanding_metadata_fetches);
+ ostree_async_progress_set_uint (pull_data->progress, "metadata-fetched", pull_data->n_fetched_metadata);
+
if (pull_data->fetching_sync_uri)
{
gs_free char *uri_string = soup_uri_to_string (pull_data->fetching_sync_uri, TRUE);
GString *buf;
gs_free char *status = NULL;
guint outstanding_fetches;
+ guint outstanding_metadata_fetches;
guint outstanding_writes;
guint n_scanned_metadata;
status = ostree_async_progress_get_status (progress);
outstanding_fetches = ostree_async_progress_get_uint (progress, "outstanding-fetches");
+ outstanding_metadata_fetches = ostree_async_progress_get_uint (progress, "outstanding-metadata-fetches");
outstanding_writes = ostree_async_progress_get_uint (progress, "outstanding-writes");
n_scanned_metadata = ostree_async_progress_get_uint (progress, "scanned-metadata");
if (status)
{
guint64 bytes_transferred = ostree_async_progress_get_uint64 (progress, "bytes-transferred");
guint fetched = ostree_async_progress_get_uint (progress, "fetched");
+ guint metadata_fetched = ostree_async_progress_get_uint (progress, "metadata-fetched");
guint requested = ostree_async_progress_get_uint (progress, "requested");
guint64 bytes_sec = (g_get_monotonic_time () - ostree_async_progress_get_uint64 (progress, "start-time")) / G_USEC_PER_SEC;
gs_free char *formatted_bytes_transferred =
formatted_bytes_sec = g_format_size (bytes_sec);
}
- g_string_append_printf (buf, "Receiving objects: %u%% (%u/%u) %s/s %s",
- (guint)((((double)fetched) / requested) * 100),
- fetched, requested, formatted_bytes_sec, formatted_bytes_transferred);
+ if (outstanding_metadata_fetches)
+ {
+ g_string_append_printf (buf, "Receiving metadata objects: %u/(estimating) %s/s %s",
+ metadata_fetched, formatted_bytes_sec, formatted_bytes_transferred);
+ }
+ else
+ {
+ g_string_append_printf (buf, "Receiving objects: %u%% (%u/%u) %s/s %s",
+ (guint)((((double)fetched) / requested) * 100),
+ fetched, requested, formatted_bytes_sec, formatted_bytes_transferred);
+ }
}
else if (outstanding_writes)
{